package cn.com.simple.learning.rabbitmq.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author Jianxing.Jia
 * @date 2022/5/25
 * @description 描述信息
 */
public interface StreamDelayPipeline {

    String SEND = "delay_event_send";
    String RECV = "delay_event_recv";

    @Output(SEND)
    MessageChannel sendChannel();

    @Input(RECV)
    SubscribableChannel recvChannel();

}
